package com.qfjy.controller.example4;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

@Controller
@RequestMapping("blog")
@Slf4j
public class BlogController {

    @Autowired
    private AmqpTemplate amqpTemplate;
    @GetMapping("sendBlog")
    @ResponseBody
    public String sendBlog(HttpServletRequest request){
        //主题交换机的`routing_key`需要有一定的规则，
        // 交换机和队列的`binding_key`需要采用`*.#`的格式，每个部分用`.`分开，其中：  key= blog.java
        String key=request.getParameter("key");
        //内容
        String msg=request.getParameter("msg");

        /**
         String exchange, String routingKey, Object object
         @param1 exchange 交换机名称
         @param2 routingkey 路由key
         @param3 object 数据对象（传输数据）
         */
        amqpTemplate.convertAndSend("blogTopicExchange",key,msg);


        return "博客发送成功-->"+key+"\t"+msg;
    }
}
